package com.aiwiown.snackmq.common.handler;

import com.aiwiown.snackmq.common.message.Message;

/**
 * 消息处理器接口
 */
public interface MessageProcessor {
    
    /**
     * 处理发布消息
     *
     * @param message 消息
     * @return 处理结果
     */
    Message processPublish(Message message);
    
    /**
     * 处理消费消息
     *
     * @param message 消息
     * @return 处理结果
     */
    Message processConsume(Message message);
    
    /**
     * 处理确认消息
     *
     * @param message 消息
     * @return 处理结果
     */
    Message processAck(Message message);
    
    /**
     * 处理心跳消息
     *
     * @param message 消息
     * @return 处理结果
     */
    Message processHeartbeat(Message message);
} 